package com.wzl.producer.service.kafkaService.impl.basicsProducer;

import com.wzl.common.pojo.VkSmbmsUser;
import com.wzl.producer.mapper.kafkaMapper.basicsProducer.MqBasicKafkaProMapper;
import com.wzl.producer.service.kafkaService.basicsProducer.MqBasicsKafkaProService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * kafka基本使用接口实现类
 *
 * @author weizhongli
 * @since 2022-09-13 11:04
 */
@Service
public class MqBasicsKafkaProServiceImpl implements MqBasicsKafkaProService {

    @Resource
    private MqBasicKafkaProMapper mqBasicKafkaProMapper;

    @Override
    public VkSmbmsUser queryUserById(int id) {
        VkSmbmsUser user = mqBasicKafkaProMapper.queryUserById(id);
        return user;
    }
}